//
//package com.windy.kafka.sender.annotation;
//
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.kafka.support.KafkaHeaders;
//import org.springframework.messaging.handler.annotation.TracingHeader;
//import org.springframework.messaging.handler.annotation.Payload;
//import org.springframework.stereotype.Component;
//
//@Component
//public class Listener {
//
//  @KafkaListener(topics = "spring")
//  public void listen(@Payload String message,
//                     @TracingHeader(value = KafkaHeaders.TOPIC, required = false) String topic,
//                     @TracingHeader(value = KafkaHeaders.MESSAGE_KEY, required = false) String key,
//                     @TracingHeader(value = KafkaHeaders.PARTITION_ID, required = false) Integer partitionId,
//                     @TracingHeader(value = "x-trace-id", required = false) String traceId) {
//
//    System.out.println(message);
//  }
//
//}
